2716b68a7da1650f8bf9b6ab3e03749ea35751e2,src/test/java/com/ociweb/pronghorn/stage/RingBufferPipeline.java,DumpStageLowLevel,run,#,97

Before Change


		        	
			while (Pipe.hasContentToRead(inputRing, msgSize)) {
		        	
		            Pipe.takeMsgIdx(inputRing);
		            Pipe.confirmLowLevelRead(inputRing, msgSize);
		        	int meta = takeRingByteMetaData(inputRing);
		        	int len = takeRingByteLen(inputRing);

After Change


		        	
			while (Pipe.hasContentToRead(inputRing, msgSize)) {
		        	
		            if (Pipe.takeMsgIdx(inputRing)<0) {
		            	  Pipe.confirmLowLevelRead(inputRing, msgSize);
		            	  Pipe.releaseReadLock(inputRing);
		            	requestShutdown();